package com.example.demo.common;

import com.example.demo.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * Created with IntelliJ IDEA.
 * Description:
 * User: 张
 * Date: 2024-08-20
 * Time: 9:51
 */
//单纯的函数式接口(回调函数),接收到消息之后处理消息时调用的方法
@FunctionalInterface
public interface Consumer {
    // Delivery 的意思是"投递",这个方法预期是在每次服务器收到消息之后,来调用
    // 通过这个方法把消息推送给对应的消费者
    void handleDelivery(String consumerTag, BasicProperties basicProperties,byte[] body) throws MqException, IOException;
}
